package com.example.kafkatesttool;


import lombok.AllArgsConstructor;
import lombok.Data;

@Data
@AllArgsConstructor
public class KafkaMessage {

    private String topic;

    private long offset;
    private int partition;

    private String message;

    private String timestamp;





}
